const Controller = require('egg').Controller;

const ejs = require('ejs');

const tmdir = '/Users/changsichong/Desktop/workspace/svnspace/framework/fd_core_server/app/template/'

class gen extends Controller {


  async clgen() {
    const { ctx, service ,app} = this;
    let name = ctx.request.query.name;
    let age = ctx.request.query.age;
    await ctx.helper.sendQueueMsg('q',{name:name,age:age});
    //   await ctx.helper.receiveQueueMsg()
    ctx.body = {
        code : '200'
    }

    // await app.redis.set('acount',300);
    //
    // // let job = app.mainq.create('email', {
    // //     title: 'welcome email for tj'
    // //   , to: 'tj@learnboost.com'
    // //   , template: 'welcome-email'
    // // }).save( function(err){
    // //   if( !err ) console.log( job.id );
    // // });
    //
    // let job1 = app.mainq.create('email', {
    //     id: '1'
    //     , type: '提现'
    //     , sql: '第一次提现'
    // }).save( function(err){
    //     if( !err ) console.log( job1.id );
    // });
    //
    //   job1.on('complete', function(result){
    //       console.info('Job completed with data ', result);
    //   });
    //
    //   let job3 = app.mainq.create('email', {
    //       id: '2'
    //       , type: '提现'
    //       , sql: '第二次提现'
    //   }).save( function(err){
    //       if( !err ) console.log( job3.id );
    //   });
    //
    // let job2 = app.mainq.create('email', {
    //     id: '3'
    //     , type: '进账'
    //     , sql: '第一次进账'
    // }).save( function(err){
    //     if( !err ) console.log( job2.id );
    // });
    //
    //   let job4 = app.mainq.create('email', {
    //       id: '1'
    //       , type: '提现'
    //       , sql: '第三次提现'
    //   }).save( function(err){
    //       if( !err ) console.log( job4.id );
    //   });
    //
    //
    //   // job3.on('complete', function(result){
    //   //     console.info('Job completed with data ', result);
    //   //     ctx.body = {code:"200",msg:"成功"}
    //   // }).on('failed', (errorMessage)=>{
    //   //     console.info('Job failed');
    //   //     console.info(errorMessage);
    //   //     ctx.body = {code:"200",msg:"失败"}
    //   //
    //   // });
    //
    //   return new Promise((resolve, reject) => {
    //
    //       job3.on('complete', function(result){
    //           console.log('clgen ', result);
    //           ctx.body = {code:"0",msg:"成功"}
    //           resolve("成功")
    //
    //       }).on('failed', function(errorMessage, doneAttempts){
    //           console.log('clgen failed');
    //           ctx.body = {code:"0",msg:"失败"}
    //           resolve("失败")
    //       })
    //
    //   });


      // let str = await ejs.renderFile(tmdir+'cl.ejs')
    // console.info(str)


  }







}
module.exports = gen;
